package com.example.d7_thread_communication;

/**
 * 目标：了解一下线程通信
 */
public class ThreadTest {
    public static void main(String[] args) {
        // 什么是线程通信：当多个线程共同操作共享资源时,线程间通过某种方式互相告知自己的状态,以相互协调,避免无效的资源挣抢
        // 线程通信的常见模型：生产者消费者模型
        // 需求：3个生产者线程,负责生产包子,每个线程每次只能生产1个包子放在桌子上 2个消费者线程负责吃包子,每人每次只能从桌子上拿1个包子吃
        Desk desk = new Desk();

        // 创建3个生产者线程（3个厨师）
        new Thread(() -> {
            while (true) {
                desk.put();
            }
        }, "厨师1").start();

        new Thread(() -> {
            while (true) {
                desk.put();
            }
        }, "厨师2").start();

        new Thread(() -> {
            while (true) {
                desk.put();
            }
        }, "厨师3").start();


        // 创建2个消费者线程（2个吃货）
        new Thread(() -> {
            while (true) {
                desk.get();
            }
        }, "吃货1").start();

        new Thread(() -> {
            while (true) {
                desk.get();
            }
        }, "吃货2").start();
    }
}
